package com.fine.spark.connector.base.worker

import com.fine.spark.connector.base.beans.process.ClassProcessConfig
import org.apache.spark.sql.SparkSession

/**
 * 自定义代码必须实现这个接口
 *
 * @author jayce
 * @date 2021/11/21 3:03 PM
 * @version 1.0
 */
trait ClassBaseWorker extends BaseWorker {
  def main(config: ClassProcessConfig)(implicit ss: SparkSession): Unit
}
